package com.example.mq.mqserver.core;

import com.example.mq.common.MqException;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    //每次服务器收到消息 调用 把消息推送给消费者
    //此处参考rabbitMq
    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
